Jeg jobber med forsøksoperatøren i RxSwift. I følge dokumentasjonen "abonnerer den" på kilden som kan observeres når den støter på en feil. Dette er vel og bra. Jeg er imidlertid ikke helt sikker på hvordan jeg skal resonnere om "kilden som kan observeres" når den inneholder varme observerbare, eller en blanding av varme / kalde observerbare. Et eksempel jeg er sikker på: let coldObservable = Observable.interval (.seconds (1), scheduler: MainScheduler.instance) la coldObservableRetry = coldObservable.flatMapLatest {num in hvis num% 3 == 0 {return .just (num)} annet {return. feil ()} } .forsøk (2) // prøv på nytt inkluderer originalt forsøk coldObservableRetry.subscribe (onNext: {print ($ 0)}) // skriver ut 1, 2, 1, 2, før du feiler ut. Et eksempel jeg ikke er sikker på: let hotObservable = Observable .interval (.seconds (1), scheduler: MainScheduler.instance) .publish (). connect () la hotObservableRetry = hotObservable.flatMapLatest {num in hvis num% 3 == 0 {return .just (num)} annet {return. feil ()} } .forsøke (2) hotObservableRetry.subscribe (onNext: {print ($ 0)}) // Hva skjer her? Et annet eksempel jeg ikke er sikker på: let coldObservable = Observable .interval (.seconds (1), scheduler: MainScheduler.instance) let delayedHotObservable = Observable .interval (.seconds (1), scheduler: MainScheduler.instance) .delay (.milliseconds (100), scheduler: MainScheduler.instance) .publish (). connect () la blandingenObservableRetry = Observable.combineLatest (coldObservable, delayedHotObservable) .kart {$ 0 + $ 1} .flatMapLatest {num in hvis num% 3 == 0 {return .just (num)} annet {return. feil ()} } .retry (5) blandingObservableRetry.subscribe (onNext: {print ($ 0)}) // Hva skjer her? Hva betyr det til og med å abonnere på en combineLatest med en varm og kald observerbar? Nok et eksempel jeg ikke er sikker på: let coldObservable = Observable .interval (.seconds (1), scheduler: MainScheduler.instance) let hotObservable = Observable .interval (.seconds (1), scheduler: MainScheduler.instance) .publish (). connect () la blandingObservable2Retry = coldObservable.flatMapLatest {_ i hotObservable} .flatMapLatest {num i hvis num% 3 == 0 {return .just (num)} annet {return. feil ()} } .forsøke (2) mixedObservable2Retry.subscribe (onNext: {print ($ 0)}) // Hva skjer her?
2021-02-26 08:17:57
Mange av eksemplene dine kompilerer ikke, så det som skjer er at du får en kompileringsfeil. :-) Men for å svare på spørsmålet ...
Det er noen viktige ting å huske på.
Hver operatør abonnerer på kilden som kan observeres og genererer en ny observerbar.
Når et kaldt observerbart abonnement abonnerer på, vil det sende ut 0 ... N neste hendelser og deretter en stopphendelse (som enten er fullført eller feil.) Det vil gi hvert abonnement sitt eget sett med hendelser.
Hot observables begynner ikke å sende ut før tilkoblingen blir kalt. Alle abonnementene vil dele det samme settet med hendelser.
Til slutt i dette tilfellet er feilsøking din venn.
Så for ditt første eksempel er du ikke sikker på (justert slik at den kompileres og kjøres med noen feilsøkingsoperatører lagt til):
funk eksempel () {
let hotObservable = Observable .interval (.seconds (1), scheduler: MainScheduler.instance)
.debug ("før publisering")
.publisere()
la hotObservableRetry = hotObservable
.debug ("etter publisering")
.map {(num) -> Int in
vakt nummer% 3! = 0 annet {kast MyError ()}
retur nummer
}
.debug ("etter kart")
.forsøke (2)
.debug ("etter prøv på nytt")
_ = hotObservableRetry.subscribe ()
_ = hotObservable.connect ()
}
Vil produsere nedenstående utdata.
Her er noen ting å merke seg om utdataene som vil hjelpe i læringsprosessen.
Abonnementene skjer i omvendt rekkefølge.
Når den første feilen er utgitt, abonnerer forsøksoperatøren på nytt på kartoperatørens observerbare, som abonnerer på publiseringens observerbare. Siden publiseringens observerbare er varmt, stopper abonnementskjeden der. Tidtakeren kan observeres, blir ikke abonnert på nytt.
Ovennevnte er de viktigste punktene å forstå for å svare på dette spørsmålet.
etter prøv på nytt -> abonnerer
etter kart -> abonnerer
etter publisering -> abonnerer
før publisering -> abonnerer
før publisering -> Event neste (0)
etter publisering -> Event neste (0)
etter kart -> Hendelsesfeil (MyError ())
etter kart -> er disponert
etter publisering -> er disponert
etter kart -> abonnerer
etter publisering -> abonnerer
før publisering -> Event neste (1)
etter publisering -> Event neste (1)
etter kart -> Event neste (1)
etter prøve på nytt -> Event neste (1)
før publisering -> Event neste (2)
etter publisering -> Event neste (2)
etter kart -> Event neste (2)
etter prøve på nytt -> Event neste (2)
før publisering -> Event neste (3)
etter publisering -> Event neste (3)
etter kart -> Hendelsesfeil (MyError ())
etter nytt forsøk -> Hendelsesfeil (MyError ())
etter prøve på nytt -> er disponert
etter kart -> er disponert
etter publisering -> er disponert
før publisering -> Event neste (4)
før publiser -> Event neste (5)
før publisering -> Event neste (6)
...
I det neste eksemplet du viste, abonnerer combineLatest-operatøren på det waarne som kan observeres, men det som kan kobles, abonnerer ikke på kilden på nytt.
7
|
Ditt svar
StackExchange.ifUsing ("editor", function () {
StackExchange.using ("externalEditor", funksjon () {
StackExchange.using ("snippets", function () {
StackExchange.snippets.init ();
});
});
}, "kodebiter");
StackExchange.ready (funksjon () {
var channelOptions = {
tagger: "" .split (""),
id: "1"
};
initTagRenderer ("". split (""), "" .split (""), channelOptions);
StackExchange.using ("externalEditor", funksjon () {
// Må utløse redaktøren etter utdrag, hvis utdrag er aktivert
hvis (StackExchange.settings.snippets.snippetsEnabled) {
StackExchange.using ("snippets", function () {
createEditor ();
});
}
annet {
createEditor ();
}
});
funksjon createEditor () {
StackExchange.prepareEditor ({
useStacksEditor: false,
hjerteslagType: 'svar',
autoActivateHeartbeat: false,
convertImagesToLinks: sant,
noModals: sant,
showLowRepImageUploadWarning: true,
reputToPostImages: 10,
bindNavPrevention: true,
postfix: "",
imageUploader: {
brandingHtml: "Drevet av \ u003ca href = \" https: //imgur.com/ \ "\ u003e \ u003csvg class = \" svg-icon \ "width = \" 50 \ "height = \" 18 \ "viewBox = \ "0 0 50 18 \" fill = \ "none \" xmlns = \ "http: //www.w3.org/2000/svg \" \ u003e \ u003cpath d = \ "M46.1709 9.17788C46.1709 8.26454 46.2665 7.94324 47.1084 7.58816C47.4091 7.46349 47.7169 7.36433 48.0099 7.26993C48.9099 6.97997 49.672 6.73443 49.672 5.93063C49.672 5.22043 48.9832 4.61182 48.1414 4.61182C47.4335 4.61182 46.7256 4.916 43.1481 6.59048V11.9512C43.1481 13.2535 43.6264 13.8962 44.6595 13.8962C45.6924 13.8962 46.1709 13.2535 46.1709 11.9512V9.17788Z \ "/ \ u003e \ u003cpath d = \" M32.492 10.1419C4.4.014.412 12.6 41.5985 12.6954 41.5985 10.1419V6.59049C41.5985 5.28821 41.1394 4.66232 40.1061 4.66232C39.0732 4.66232 38.5948 5.28821 38.5948 6.59049V9.60062C38.5948 10.8521 38.2696 11.5455 37.0451 11.445.5 521 35.4954 9.60062V6.59049C35.4954 5.28821 35.0173 4.66232 34.0034 4.66232C32.9703 4.66232 32.492 5.28821 32.492 6.59049V10.1419Z \ "/ \ u003e \ u003cpath fill-rule = \" evenodd \ "clip-rule = \" evend = \ "M25.6622 17.6335C27.8049 17.6335 29.3739 16.9402 30.2537 15.6379C30.8468 14.7755 30.9615 13.5579 30.961511.9512V6.59049C30.9615 5.28821 30.4833 4.66231 29.4502 4.66231C28.9913 4.66231 28.4555 4.94978 28.1109 5.50789C27.499 4.86533 26.7335 4.56087 25.7005 4.56087C23.1369 4.56087 21.0134 6.57349 21.0134 23.013.0 12.6616C28.1109 12,7229 28,1161 12,7799 28,121 12.8346C28.1256 12,8854 28,1301 12,9342 28,1301 12.983C28.1301 14,4373 27,2502 15,2321 25,777 15.2321C24.8349 15,2321 24,1352 14,9821 23,5661 14.7787C23.176 14,6393 22,8472 14,5218 22,5437 14.5218C21.7977 14,5218 21,2429 15,0123 21,2429 15.6887C21 .2429 16.7375 22.9072 17.6335 25.6622 17.6335ZM24.1317 9.27932C24.1317 7.94324 24.9928 7.09766 26.1024 7.09766C27.2119 7.09766 28.0918 7.94324 28.0918 9.27932C28.0918 10.6321 27.2311 11.5116 26.1024 11.511611 u003cpath d = \ "M16.8045 11.9512C16.8045 13.2535 17.2637 13.8962 18.2965 13.8962C19.3298 13.8962 19.8079 13.2535 19.8079 11.9512V8.12928C19.8079 5.82936 18.4879 4.62866 16.4027 4.62866C15.1594 4.62866 14.279 4.98375 13.3609 5.88013C12.653 5.05154 11.6581 4.62866 10.3573 4.62866C9.34336 4.62866 8.57809 4.89931 7.9466 5.5079C7.58314 4.9328 7.10506 4.66232 6.56666 5.47873 13.8962 6.51203 13.8962C7.54479 13.8962 8.0232 13.2535 8.0232 11.9512V8.90741C8.0232 7.58817 8.44431 6.91179 9.53458 6.91179C10.5104 6.91179 10.893 7.58817 10.893 8.94108V11.9512.8.8 90741C13.9157 7.58817 14.3365 6.91179 15.4269 6.91179C16.4027 6.91179 16.8045 7.58817 16.8045 8.94108V11.9512Z \ "/ \ u003e \ u003cpath d = \" M3.31675 6.59049C3.31675 5.28821 2.83866 4.662321.7170 V1.9595C0.313354 13.2535 0.791758 13.8962 1.82471 13.8962C2.85798 13.8962 3.31675 13.2535 3.31675 11.9512V6.59049Z \ "/ \ u003e \ u003cpath d = \" M1.87209 0.400291C0.843612 0.400291 0 1.1159 0 1.98861C0 2.87869 0.822846 3.57676 1.87209 3.57676C2.90056 3.57676 3.7234 2.87869 3.7234 1.98861C3.7234 1.1159 2.90056 0.400291 1.87209 0.400291Z \ "fill = \" # 1BB76E \ "/ \ u003g \ u00 \ u003g \ u003c \ u003e ",
contentPolicyHtml: "Brukerbidrag lisensiert under \ u003ca href = \" https: //stackoverflow.com/help/licensing \ "\ u003ecc by-sa \ u003c / a \ u003e \ u003ca href = \" https://stackoverflow.com / legal / content-policy \ "\ u003e (policy for innhold) \ u003c / a \ u003e",
allowUrls: sant
},
onDemand: sant,
discardSelector: ".discard-answer"
, straksShowMarkdownHelp: true, enableTables: true, enableSnippets: true
});
}
});
Takk for at du bidro med svaret på Stack Overflow!
Sørg for å svare på spørsmålet. Gi detaljer og del din forskning!
Men unngå ...
Be om hjelp, avklaring eller svare på andre svar.
Å komme med uttalelser basert på mening; sikkerhetskopier dem med referanser eller personlig erfaring.
For å lære mer, se tipsene våre for å skrive gode svar.
Utkast lagret
Utkast kastet
Registrer deg eller logg inn
StackExchange.ready (funksjon () {
StackExchange.helpers.onClickDraftSave ('# login-link');
});
Registrer deg ved hjelp av Google
Registrer deg ved hjelp av Facebook
Registrer deg ved hjelp av e-post og passord
Sende inn
Legg ut som gjest
Navn
E-post
Påkrevd, men aldri vist
StackExchange.ready (
funksjon () {
StackExchange.openid.initPostLogin ('. New-post-login', 'https% 3a% 2f% 2fstackoverflow.com% 2fquestions% 2f64950463% 2fhow-do-rxswift-operators-affect-resubscribes% 23new-answer', 'question_page' );
}
);
Legg ut som gjest
Navn
E-post
Påkrevd, men aldri vist
Legg ut svaret ditt
Kast
Ved å klikke på “Legg ut svaret ditt” godtar du våre vilkår for bruk, personvernregler og policy for informasjonskapsler
Er ikke svaret du leter etter? Bla gjennom andre spørsmål merket ios swift5 rx-swift, eller still ditt eget spørsmål.